package com.funny.rabbitmq.helloworld;

import com.funny.rabbitmq.utils.RabbitMQUtils;
import com.rabbitmq.client.Channel;

public class Producer {

    private final static String QUEUE_NAME = "hello";

    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMQUtils.getChannel();

        /**
         * 生产者参数
         * 1.消息队列名
         * 2.队列中的消息是否是持久化， true：持久化，false(默认)：内存中
         * 3.该队列是否只供一个消费者进行消费，是否进行消息共享，true：可以多个消费者消费，false：只能一个消费者消费
         * 4.是否自动删除，最后一个消费者断开连接后，该队是否自动删除，true：自动删除，false: 不自动删除
         * 5.其他参数
         */
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        StringBuilder msg = new StringBuilder("hello world");
        for (int i = 0; i < 10; i++) {
            msg.append(i);
            channel.basicPublish("", QUEUE_NAME, null, msg.toString().getBytes());
            System.out.println("消息发送成功");
        }
    }
}
